import time
import socket
import co2_serial
import requests

hostname = socket.gethostname()
cityserver = "172.16.13.7"
db_name = "co2_sensor"
record_name = "co2_measure"
username = "influx_user"
password = "w1GYhmBvo"

co2Sensor = co2_serial.co2Sensor()

while True:
    try:
        co2 = co2Sensor.readCO2Level()
        co2_rounded = round(co2, 2)
        print(f"La valeur mesurée est de {co2_rounded} ppm")

        data = f"{record_name},host={hostname} value={co2_rounded}"
        url = f"http://{cityserver}:8086/write?u={username}&p={password}&db={db_name}"
        response = requests.post(url, data=data)

        if response.status_code != 204:
            print(f"Erreur InfluxDB: {response.status_code}, {response.text}")

    except Exception as e:
        print(f"Erreur de lecture ou d'envoi: {e}")

    time.sleep(1)